from pyspark.context import SparkContext

sc = SparkContext(master='local',appName='word_count')

students_rdd = sc.textFile('../../data/students.txt')


filter_rdd = students_rdd.filter(lambda x:x.split(',')[3]=='男')

filter_rdd.foreach(print)